#include <iostream>
#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/shm.h>
#include <cstring>
#include "comm.hpp"
#include <unistd.h>
using namespace std;
class Init
{
public:
    Init()
    {
        // 创建命名管道
        bool r = makefifo();
        if (!r)
            return;

        key_t key = getkey();
        std::cout << "key: " << ToHex(key) << std::endl;

        shmid = CreateShm(key);
        cout << "共享内存开辟成功, shmid为：" << shmid << endl;

        cout << "开始将shm映射到进程的地址空间中去" << endl;
        s = (char *)shmat(shmid, nullptr, 0);
        // 共享内存是不会提供同步机制的，共享内存是直接裸露给所有的使用者的，一定要注意共享内存的使用安全问题

        rfd = open(filename.c_str(), O_RDONLY);
    }
    ~Init()
    {
        shmdt(s);
        cout << "开始将shm从进程的地址空间中移除" << endl;

        shmctl(shmid, IPC_RMID, nullptr);
        cout << "开始将shm从os中移除" << endl;
        close(rfd);
        unlink(filename.c_str());
    }

public:
    int rfd;
    char *s;
    int shmid;
};
int main()
{
    Init init;
    while (true)
    {
        int code = 0;
        ssize_t n = read(init.rfd, &code, sizeof(code));
        if (n > 0)
        {
            cout << "共享内存中的内容是：" << init.s << endl;
            sleep(1);
        }
        else if (n == 0)
        {
            break;
        }
    }

    return 0;
}